package com.mango.ch03;

import java.io.Serializable;
import java.util.Comparator;

import scala.Tuple2;

/**
 * 实现这个比较器 必须要实现Java原生的序列化接口 否则spark框架抛出未序列化异常
 * 
 * @author Mango
 *
 *         2018年8月1日-下午5:18:15
 */
@SuppressWarnings("serial")
public class TopN_Tuple2Compartor implements Comparator<Tuple2<String, Integer>>, Serializable {

	@Override
	public int compare(Tuple2<String, Integer> o1, Tuple2<String, Integer> o2) {
		// TODO Auto-generated method stub

		return -o1._2.compareTo(o2._2);// 降序排序
	}

}
